package com.lac.component.rabbitmq.seq;

import com.lac.component.model.MessageInfo;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @author xiaokuixiao
 * date2025/7/1 15:07
 */
@Component
@RabbitListener(id = "SingleActiveListener1",
        queues = {"triple_queue_one", "triple_queue_two", "triple_queue_three"})
public class SingleActiveListener {
    @RabbitHandler
    public void handler(MessageInfo message) {
//        System.out.println("SingleActiveListener1 消费" + message.getMessage());
    }
}
